package com.lagou.lagoustreamproducer;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.annotation.Bean;
import java.util.function.Consumer;
import java.util.function.Supplier;

//@EnableDiscoveryClient
@SpringBootApplication
public class LagouStreamProducerApplication {

    public static void main(String[] args) {
        SpringApplication.run(LagouStreamProducerApplication.class, args);
    }
    //定时发送消息，每秒发送一条消息
//    @Bean
//    public Supplier<String> test(){
//        System.out.println("发送消息");
//        return () -> "text";
//    }



}
